google.golang.org/grpc.serverStream.decompressorV1 (field)
5 uses
google.golang.org/grpc (current package)
server.go#L1682: ss.decompressorV1 = encoding.GetCompressor(rc)
server.go#L1683: if ss.decompressorV1 == nil {
stream.go#L1594: decompressorV1 encoding.Compressor
stream.go#L1778: if err := recv(ss.p, ss.codec, ss.s, ss.decompressorV0, m, ss.maxReceiveMessageSize, payInfo, ss.decompressorV1, true); err != nil {
stream.go#L1824: if err := recv(ss.p, ss.codec, ss.s, ss.decompressorV0, m, ss.maxReceiveMessageSize, nil, ss.decompressorV1, true); err == io.EOF {